def send_to_kafka(msgs):
    pass
